package com.xiaohongshu.kafkademo.event;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Map;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class DataChangeEvent {
    private String database;
    private String table;
    private String eventType; // INSERT, UPDATE, DELETE
    private Map<String, Object> beforeData;
    private Map<String, Object> afterData;
    private Long executeTime;
    private Long id; // 主键ID
}
